//package com.untour.im.codec.protocol.coder;
//
//import com.untour.im.codec.constants.IMConstants;
//import com.untour.im.codec.protocol.packet.Packet;
//import com.untour.im.codec.protocol.packet.PacketCodec;
//import io.netty.buffer.ByteBuf;
//import io.netty.channel.ChannelHandlerContext;
//import io.netty.handler.codec.MessageToMessageDecoder;
//import io.netty.handler.codec.http.websocketx.BinaryWebSocketFrame;
//import lombok.extern.slf4j.Slf4j;
//
//import java.util.List;
//
//@Slf4j
//public class WebSocketMessageDecoder extends MessageToMessageDecoder<BinaryWebSocketFrame> {
//    @Override
//    protected void decode(ChannelHandlerContext ctx, BinaryWebSocketFrame msg, List<Object> out) throws Exception {
//        ByteBuf byteBuf = msg.content();
//        if (byteBuf.readableBytes() < IMConstants.PROTOCOL_HEADER_LENGTH) {
//            return;
//        }
//        Packet message = PacketCodec.INSTANCE.decode(byteBuf);
//        if (message == null) {
//            log.warn("本次读取数据不完整，下次再读取");
//            return;
//        }
//        out.add(message);
//    }
//}
